package com.stone.customer.console.job.impl;

import com.stone.customer.console.infra.constant.CustomerConsoleConstant;
import com.stone.customer.console.job.AbstractReceiverFromRedisTriggerJob;
import com.stone.message.adapter.infra.publisher.MessagePublisher;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

/**
 * 会员信息同步job实现
 *
 * @author Mr_wenpan@163.com 2021/07/17 18:35
 */
@Slf4j
@Component
public class CustomerSyncReceiverJob extends AbstractReceiverFromRedisTriggerJob {

    public CustomerSyncReceiverJob(MessagePublisher messagePublisher) {
        super(messagePublisher);
    }

    @Override
    protected String jobName() {
        return CustomerConsoleConstant.JobName.CUSTOMER_INFO_SYNC_JOB;
    }

    @Override
    protected String messageQueueName() {
        return CustomerConsoleConstant.MessageQueueName.CUSTOMER_INFO_SYNC_MESSAGE_QUEUE;
    }

    @Override
    protected String redisQueueName() {
        return CustomerConsoleConstant.RedisQueueName.CUSTOMER_INFO_SYNC_QUEUE;
    }
}
